package flinkstudy.table;

import flinkstudy.table.environment.FlinkStreamingQuery;
import org.junit.Before;
import org.junit.Test;

/**
 * @author daocr
 * @date 2020/2/6
 */
public class TemporalApi {

    private FlinkStreamingQuery flinkStreamingQuery;


    @Before
    public void init() {
        flinkStreamingQuery = new FlinkStreamingQuery();
    }


    @Test
    public void createTemporalApi() {

    }

}
